import pandas as pd
import numpy as np

# pandas加载数据
# --- csv数据
# --- Excel数据
# --- MySQL数据

print('1.csv数据加载')
# data = np.random.randint(1, 50, (10, 5))
# df = pd.DataFrame(data,columns=['python','java','c++','php','javascript'])
# print(df)

"""
sep:分隔符，默认是','
index:是否保存行索引，默认是True
header:是否保存列名，默认是True
"""
# 保存到csv文件
# df.to_csv('data.csv',sep=',',index=True,header=True)
# 读取csv文件
# df = pd.read_csv('data.csv',sep=',',index_col=0)
# print(df)
# print('\n')
# # 不获取列：header=None
# df1 = pd.read_csv('data.csv',sep=',',index_col=0,header=None)
# print(df1)
# """
# pd.read_csv():
#    -- sep是可以不加的
# pd.read_table():
#    -- sep是必须要加的
# """
# pd2= pd.read_csv('data.csv',sep=',',index_col=0)
# print(pd2)

print('\n2.Excel数据加载')

# data = np.random.randint(1, 50, (10, 5))
# df_excel = pd.DataFrame(data,columns=['python','java','c++','php','javascript'])
# print(df_excel)
# # 保存到Excel文件
# df_excel.to_excel('data.xlsx',sheet_name='sheet1',index=True,header=True)
# 读取Excel文件
# pd_excel = pd.read_excel('data.xlsx',sheet_name='sheet1',index_col=0)
# print(pd_excel)
# """
# sheet_name:指定读取的sheet名，默认是0
# index_col:指定读取的行索引，默认是0
# names:指定列名，默认是None,替换原有列名
# """

print('\n3.MySQL数据加载')
from sqlalchemy import create_engine
"""
mysql+pymysql://用户名:密码@主机地址:端口号/数据库名
root:root :数据库用户名和密码
localhost：3306 ：数据库地址和mysql端口
"""
connection_str ="mysql+pymysql://data_user:data_user#2024@mysql.xiangcunshenghuo.com:13306/exhibition_data_test"

# # 保存到数据库
# df.to_sql(
#     name='数据库中表的名称',# 数据库中表的名称
#     con=connection_str,  # 数据库连接对象
#     index=True,  # 是否保存行索引
#     if_exists='append',# 如果表存在，则追加数据
# )


# 从数据库读取数据
pd_mysql = pd.read_sql(
    sql='SELECT * FROM exhibition_data_test.fh_china_area', # 查询语句
    con=connection_str,  # 数据库连接对象
    # index_col='id'  # 指定行索引的列名
)
print(pd_mysql)




